package com.jthinking.test.serializer;

import com.jthinking.test.proto.ImageProto;
import org.apache.kafka.common.serialization.Serializer;

import java.util.Map;

public class ImageProtobufSerializer implements Serializer<ImageProto.Image> {

    @Override
    public void configure(Map<String, ?> configs, boolean isKey) {

    }

    @Override
    public byte[] serialize(String topic, ImageProto.Image image) {
        return image.toByteArray();
    }

    @Override
    public void close() {

    }
}
